import socket
import threading
def recv_msg(udp_socket):
    '''接收数据并显示'''
    while True:
        recv_data = udp_socket.recvfrom(1024)
        print(recv_data)

def send_msg(udp_socket):
    '''发送数据'''
    while True:
        send_data = input('请输入要发送的数据:')
        udp_socket.sendto(send_data.encode('utf-8'), (des_ip, dest_port))

def main():
    '''完成udp聊天器的整体控制'''
    udp_socket=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
    udp_socket.bind(('',7890))
    dest_ip=input('请输入对方的ip:')
    dest_port=int(input('请输入对方的端口:'))

    #创建两个线程
    t_recv=threading.Thread(target=recv_msg,args=(udp_socket,))
    t_send=threading.Thread(target=send_msg,args=(udp_socket,dest_ip,dest_port))

    t_recv.start()
    t_send.start()

if __name__ == '__main__':
    main()